// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init()

const db = cloud.database();
// 云函数入口函数
exports.main = async (event, context) => {
    const wxContext = cloud.getWXContext()
    try {
        //这里的keyWords是前端小程序访问的参数_keyword
        let User = await db.collection('User').limit(50).get()
        let userList = User.data
        // console.log(User)
        userList.forEach((item) => {
            wx.cloud.callFunction({
                name: "sendMsg",
                data: {
                    openid: item._openid
                }
            }).then(res => {
                console.log("推送消息成功", res)
            }).catch(res => {
                console.log("推送消息失败", res)
            })
        })
        //   .where(
        //     db.command.or([{
        //         //使用正则查询，实现对‘num’字段的搜索的模糊查询
        //         num: db.RegExp({
        //           regexp: keyWords,
        //           options: 'i', //大小写不区分
        //         }),
        //       },
        //       { 
        //         //使用正则查询，实现对‘numPort’字段的搜索的模糊查询
        //         numPort: db.RegExp({
        //           regexp: keyWords,
        //           options: 'i',//大小写不区分
        //         }),
        //       }
        //       //下面可以增加更多的选项,可以做多字段的选择
        //     ])
        //   ).get()
    } catch (e) {
        console.log(e)
    }
    // return {
    //     event,
    //     openid: wxContext.OPENID,
    //     appid: wxContext.APPID,
    //     unionid: wxContext.UNIONID,
    // }
}